package org.apache.flink.runtime.resourceconsumer;

import org.apache.flink.runtime.clusterframework.types.ResourceID;
import org.apache.flink.runtime.registration.RegistrationResponse;
import org.apache.flink.util.Preconditions;

/** Message indicating a successful {@link JobMaster} and {@link TaskExecutor} registration. */
public class RCRPRegistrationSuccess extends RegistrationResponse.Success {
    private static final long serialVersionUID = -3528383155961318929L;

    private final ResourceID resourceID;

    public RCRPRegistrationSuccess(ResourceID resourceID) {
        this.resourceID = Preconditions.checkNotNull(resourceID);
    }

    public ResourceID getResourceID() {
        return resourceID;
    }
}
